﻿using System;
using System.Data;
using System.Configuration;
using System.Collections;
using System.Linq;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Web.UI.HtmlControls;
using System.Xml.Linq;

public partial class _35newpart_Linq_DLINQ_LINQ_to_SQL_之事务处理和并发处理 : System.Web.UI.Page
{
    Linq查询DataContext LDB = new Linq查询DataContext();
    protected void Page_Load(object sender, EventArgs e)
    {
        // 事务处理（DataContext.SubmitChanges()会做默认的事务处理）
        TransactionDemo1();

        // 事务处理（用DataContext.Connection.BeginTransaction()的方式做事务处理）
        TransactionDemo2();

       
        // 事务处理
        TransactionDemo3();

        // 并发处理
        Concurrency();
    }

    /// <summary>
    /// 事务处理（DataContext.SubmitChanges()会做默认的事务处理）
    /// </summary>
    private void Concurrency()
    {
        var products = LDB.books;

        foreach (var p in products)
        {
            p.bookname = p.bookname + "1";
        }

        try
        {
            // 表示即使发生冲突也要继续
            LDB.SubmitChanges(System.Data.Linq.ConflictMode.ContinueOnConflict);
            Response.Write("表示即使发生冲突也要继续");
        }
        catch (System.Data.Linq.ChangeConflictException e)
        {
            foreach (System.Data.Linq.ObjectChangeConflict occ in LDB.ChangeConflicts)
            {
                book p = (book)occ.Object;

                // 以当前客户端中的值为准
                occ.Resolve(System.Data.Linq.RefreshMode.OverwriteCurrentValues);

                // 以当前数据库中的值为准
                occ.Resolve(System.Data.Linq.RefreshMode.KeepCurrentValues);

                // 如果数据库中的值没有发生变化，则以当前客户端中的值为准。否则，则以当前数据库中的值为准
                occ.Resolve(System.Data.Linq.RefreshMode.KeepChanges);

                foreach (System.Data.Linq.MemberChangeConflict mcc in occ.MemberConflicts)
                {
                    // 当前客户端中的值
                    string currentValue = mcc.CurrentValue.ToString();

                    // 原来数据库中的值
                    string originalValue = mcc.OriginalValue.ToString();

                    // 当前数据库中的值
                    string databaseValue = mcc.DatabaseValue.ToString();

                    // 以当前客户端中的值为准
                    mcc.Resolve(System.Data.Linq.RefreshMode.OverwriteCurrentValues);

                    // 以当前数据库中的值为准
                    mcc.Resolve(System.Data.Linq.RefreshMode.KeepCurrentValues);

                    // 如果数据库中的值没有发生变化，则以当前客户端中的值为准。否则，则以当前数据库中的值为准
                    mcc.Resolve(System.Data.Linq.RefreshMode.KeepChanges);
                }
            }

        }

        // 表示只要发生冲突就不再继续
        LDB.SubmitChanges(System.Data.Linq.ConflictMode.FailOnFirstConflict);
        Response.Write("表示只要发生冲突就不再继续");

        // ctx.SubmitChanges();

        
    }

    /// <summary>
    /// 事务处理（用DataContext.Connection.BeginTransaction()的方式做事务处理）
    /// </summary>
    private void TransactionDemo3()
    {
        
    }

    /// <summary>
    /// 事务处理
    /// </summary>
    private void TransactionDemo2()
    {
        decimal categoryId;



        if (LDB.Connection.State != ConnectionState.Open)
        {
            LDB.Connection.Open();
        }

        System.Data.Common.DbTransaction tran = LDB.Connection.BeginTransaction();

        try
        {
            categoryId = LDB.books.Max(p => p.bookid) + 1;
            LDB.books.Attach(new book { adddate = DateTime.Now, bookname = "ddfsdfs", bookid = categoryId });
            //
            LDB.books.DeleteOnSubmit(LDB.books.Single(p=>p.bookid==categoryId));

            tran.Commit();
        }
        catch
        {
            tran.Rollback();
        }
    }

    /// <summary>
    /// 并发处理
    /// </summary>
    private void TransactionDemo1()
    {
             
      book b =       new book
            {
                bookid = LDB.books.Max(p => p.bookid) + 1,
                bookname = "事务处理（DataContext.SubmitChanges()会做默认的事务处理）",
                mch = "测试数据",
                adddate = DateTime.Now,
                bookcontent = "事务处理（DataContext.SubmitChanges()会做默认的事务处理）+http://www.cnblogs.com/webabcd/archive/2007/10/24/935450.html\r\n步步为营VS 2008 + .NET 3.5(12) - DLINQ(LINQ to SQL)之事务处理和并发处理 "
            };

      book b1 = new book
           {
               bookid = LDB.books.Max(p => p.bookid) + 2,
               bookname = "事务处理（DataContext.SubmitChanges()会做默认的事务处理）2",
               mch = "2测试数据",
               adddate = DateTime.Now,
               bookcontent = "2事务处理（DataContext.SubmitChanges()会做默认的事务处理）+http://www.cnblogs.com/webabcd/archive/2007/10/24/935450.html\r\n步步为营VS 2008 + .NET 3.5(12) - DLINQ(LINQ to SQL)之事务处理和并发处理 "
               };

     

      LDB.books.Attach(b);
      LDB.books.Attach(b1);

      LDB.SubmitChanges();//执行更新
    }
}
